package com.bsj.travel.config.rocketmq.constant;

import lombok.Data;

/**
 * @author yinhao
 * @version 1.0
 * @description 消费者主题常量
 * TODO 每次新增一个rocketMq消费端则需要新增加一个group
 * @date 2023/11/9
 */
@Data
public class ConsumerGroupConstant {

    /**
     * 物联网设备消息上下行消息传递组
     */
    public static final String TRAVEL_MQTT_DOWN_MSG_GROUP = "cid-travel-mqtt-down-msg-group";
    /**
     * 物联网设备数据处理传递组
     */
    public static final String TRAVEL_MQTT_PROCESS_MSG_GROUP = "cid-travel-mqtt-process-msg-group";
    /**
     * 产品-设备消息传递组
     */
    public static final String TRAVEL_BASE_PRODUCT_GROUP = "cid-base-server-product-group";
    /**
     * 物联网设备平台上行下行日志数据存储
     */
    public static final String TRAVEL_MQTT_LOG_MSG_GROUP = "cid-travel-mqtt-log-msg-group";
    /**
     * 产品-订阅消息传递组
     */
    public static final String PRODUCT_SUBSCRIBE_GROUP = "cid-product-subscribe-group";
}
